
from fig.fig_mqtt import MqttClient
from sklearn.feature_extraction import DictVectorizer


def on_connect(client,userdata,flags,rc):
    print("Connected with result code:"+str(rc))

@MqttClient(topic="python/mqtt/topic",username="admin",password="123456")
def message(client,userdata,msg):
    print(msg.topic+" "+str(msg.payload))

if __name__ == "__main__":
    message()

